package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.vehicle.VehicleInfo;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;

/**
 * 车辆速比信息服务
 *
 * @author 沈东生
 */
public interface LoadVehicleInfoService extends Serializable{
    JavaPairRDD<Long, VehicleInfo> load(SparkSession session);
}
